import os
from celery import Celery

os.environ.setdefault("DJANGO_SETTINGS_MODULE", "fuguang.settings.dev")  # 设置项目的配置文件
app = Celery('fuguang')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()

from datetime import timedelta

app.conf.beat_schedule = {
    'add-every-30-seconds': {
        'task': 'user.tasks.add',  # 定时任务要执行的函数
        'schedule': timedelta(seconds=30),  # 定时任务的执行间隔
        'args': (10, 20)  # 传递给任务的参数
    },
    'add-every-60-seconds': {
        'task': 'user.tasks.send',  # 定时任务要执行的函数
        'schedule': timedelta(seconds=120),  # 定时任务的执行间隔
        'args': ('15647150284','1234')  # 传递给任务的参数
    }
}